

import java.io.BufferedReader;
import java.io.IOException;

/**
 * 
 * ��������� ����� ������ ��������� � ������� �������
 * 1)���������� ����������� ��������� ������
 *
 */
public class ChatServerConsoleReaderThread implements Runnable {
	private BufferedReader reader;
	ChatServer chatServer;

	ChatServerConsoleReaderThread() {
		
	}

	ChatServerConsoleReaderThread(ChatServer chatServer, BufferedReader reader) {
		this.chatServer = chatServer;
		this.reader = reader;
	}

	@Override
	public void run() {
		while (true) {
			try {
				String command = reader.readLine();
				if (command.equals("who")) {
					getWho();
				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	private synchronized void getWho() {
		for (ChatThread chatThread : chatServer.getChatThreads().values()) {
			chatServer.consoleMessage(chatThread.getLogin());
		}
	}
}
